package hy.beans;

import com.alibaba.fastjson.JSON;
import org.apache.kafka.common.serialization.Deserializer;

public class AlarmDes implements Deserializer<Msg> {
    @Override
    public Msg deserialize(String s, byte[] bytes) {
        return JSON.parseObject(bytes,Msg.class);
    }
}